ebf018f97621eccd1ca423e1bbfdc036b6b46c2c,lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java,SchedulerServiceImpl,setStateOfJob,#SchedulerJobHandle#SchedulerJobEvent#,326
Before Change
private int setStateOfJob(SchedulerJobHandle handle, SchedulerJobEvent event) throws LensException {
try {
SchedulerJobInfo info = schedulerDAO.getSchedulerJobInfo(handle);
SchedulerJobState currentState = info.getJobState();
SchedulerJobState nextState = currentState.nextTransition(event);
info.setJobState(nextState);
info.setModifiedOn(System.currentTimeMillis());
return schedulerDAO.updateJobStatus(info);
} catch (InvalidStateTransitionException e) {
throw new LensException("Invalid state ", e);
}
After Change
SchedulerJobState nextState = currentState.nextTransition(event);
info.setJobState(nextState);
info.setModifiedOn(System.currentTimeMillis());
int ret = schedulerDAO.updateJobStatus(info);
if (ret == 1) {
log.info("Successfully changed the status of job with handle {} from {} to {}", info.getId(), currentState,
nextState);
}
return ret;
} catch (InvalidStateTransitionException e) {
throw new LensException("Invalid state ", e);
}